package com.atguigu.gmall.activity.config;

import com.atguigu.gmall.activity.util.CacheHelper;
import org.springframework.stereotype.Component;

/**
 * 自定义  接收Redis发布订阅的消息 之后处理类
 */
@Component
public class MessageReceive {


    //接收消息 并处理此消息的方法
    public void receiveMessage(String message){
        //"skuId:1"或是"skuId:0"
        message = message.replaceAll("\"","");
        //切割
        String[] m = message.split(":");
        //将SkuId:状态位 保存在本地缓存中   状态位:0:无货 1：有货
        CacheHelper.put(m[0],m[1]);
    }
}
